<?php
declare (strict_types=1);

namespace app\admin\controller;

use app\BaseController;

class Server extends BaseController
{

    public function index()
    {
        try {
            // 建立socket连接到内部推送端口
            $client = stream_socket_client('tcp://127.0.0.1:5678', $errno, $errmsg, 1);
            // 推送的数据，包含uid字段，表示是给这个uid推送
            $data = array('uid' => '1', 'text' => '单独发');
            // 发送数据，注意5678端口是Text协议的端口，Text协议需要在数据末尾加上换行符
            fwrite($client, json_encode($data, 320) . "\n");
            // 读取推送结果
            echo fread($client, 8192);
        }catch (\Exception $e){
            echo $e->getMessage();
        }
    }
}
